package com.yiip.flume.interceptor;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang.StringUtils;

public class LogsUtil {

    /**
     * 校验启动日志
     *
     * @return
     */
    public static boolean validateStartLog(String content) {
        if (StringUtils.isBlank(content)) {
            return false;
        }
        if (!isJson(content)) {
            return false;
        }
        if (!content.contains("start")) {
            return false;
        }
        return true;
    }

    /**
     * 校验事件日志
     *
     * @return
     */
    public static boolean valiteEventLog(String content) {
        if (StringUtils.isBlank(content)) {
            return false;
        }
        //1、切割一下事件日志
        String[] contents = content.split("\\|");
        if(contents.length != 2){
            return false;
        }
        // 时间戳1618209574447
        if(contents[0].length() != 13) {
            return false;
        }
        if (!isJson(contents[1])) {
            return false;
        }

        return true;
    }


    public static boolean isJson(String string) {
        try {
            JSONObject jsonStr = JSONObject.parseObject(string);
            return true;
        } catch (Exception e) {
            return false;
        }
    }
}
